package com.zjc.mymq.broker.utils;

import java.util.concurrent.locks.ReentrantLock;

/**
 * @author zjc
 * @date Created in 15:58 2024/6/4
 * 
 */
public class UnfailReentrantLock implements PutMessageLock,AckMessageLock{

    private ReentrantLock reentrantLock = new ReentrantLock();


    @Override
    public void lock() {
        reentrantLock.lock();
    }

    @Override
    public void unlock() {
        reentrantLock.unlock();
    }
}
